const ws = require('nodejs-websocket')
let list={};
let connectT=null;
const server = ws.createServer(connect=>{
    console.log(`用户链接上来了`);
    // 用户传递过来的数据，text事件就会被触发
    connect.on('text',data=>{
        console.log(data)
        let {message,to,from} = JSON.parse(data);
        list[from] = connect;
        if(message=='success'){
            console.log(`用户:${from} 传来数据：${message}`);
            list[from].send(message);
        }else{
            console.log(`用户:${from} 给 用户:${to}传来数据：${message}`);
            // 返回用户信息
            list[to].send(from+':'+message)
        }
        
        
    })
    // 当连接断开时，就会执行这个事件 注册close事件就要注册下面的error事件
    connect.on('close',()=>{
        console.log(`链接断开了`+'---------'+connect.readyState);
        connectT = connect;
    })

    // 注册一个error事件，处理用户的错误信息

    connect.on('error',()=>{
        console.log(`用户链接异常`+'---------'+connect.readyState);
    })

})
function perform(){
    var i=1;
    setInterval(function(){
        console.log('执行中-----'+i +'---------'+connectT.readyState);
        list.push(i+'-------------------------');
        if(connectT.readyState == 1 ){
            connectT.send(JSON.stringify(list))
        }
        i++;
    },2000)
}
server.listen(8081,()=>{
    console.log(`服务启动成功,端口号8081`);
})